package com.ydch.spring.test.queue;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

import javax.servlet.ServletContext;

import org.springframework.beans.factory.InitializingBean;
import org.springframework.web.context.ServletContextAware;

public class BlockingQueueMessage implements InitializingBean, ServletContextAware {

	public BlockingQueue<Object> queue = new LinkedBlockingQueue<Object>();
	public BlockingQueue<Object> getQueue() {
		return queue;
	}

	public void setQueue(BlockingQueue<Object> queue) {
		this.queue = queue;
	}

	@Override
	public void setServletContext(ServletContext servletContext) {
		
	}

	@Override
	public void afterPropertiesSet() throws Exception {
		
	}

}